package com.codejiwei.flink.constant;

/**
 * @author jiwei
 * @description
 * @date 2023/5/17 17:26
 */
public class MySqlSourceConstant {
    //mysql cdc source
    public static final String FLINK_SOURCE_MYSQL_CDD = "flink.source.mysql.cdc";
    public static final String FLINK_SOURCE_MYSQL_CDC_HOST = "flink.source.mysql.cdc.host";
    public static final String FLINK_SOURCE_MYSQL_CDC_PORT = "flink.source.mysql.cdc.port";
    public static final String FLINK_SOURCE_MYSQL_CDC_USERNAME = "flink.source.mysql.cdc.username";
    public static final String FLINK_SOURCE_MYSQL_CDC_PASSWORD = "flink.source.mysql.cdc.password";
    public static final String FLINK_SOURCE_MYSQL_CDC_DATABASES = "flink.source.mysql.cdc.databases";
    public static final String FLINK_SOURCE_MYSQL_CDC_TABLES = "flink.source.mysql.cdc.tables";
    public static final String FLINK_SOURCE_MYSQL_CDC_SERVER_ID = "flink.source.mysql.cdc.server-id";

}
